package com.xinghou.mq.consumer;

import com.xinghou.mq.*;
import org.apache.log4j.Logger;

import com.xinghou.platform.server.mq.MqMessage;

/**
 * 修改更新
 * 
 * @author zhangjinwen 2016年1月6日
 */
public class CreateUpdateConsumer extends AbstractConsumer {

	private static Logger logger = Logger.getLogger(CreateUpdateConsumer.class);

	private CreateUpdateInterface createUpdateInf;

	public CreateUpdateConsumer(CreateUpdateInterface createUpdateInf, String queue, MqConfig config) {
		super(config);
		this.createUpdateInf =createUpdateInf;
	}


	protected void doWork(String task) {
		String[] datas = task.split(":");
		createUpdateInf.update(Integer.parseInt(datas[0]), datas[1].equals("U"));
	}

}
